package com.pw.study.flink.transfrom

import com.pw.study.flink.entities.UserBean
import org.apache.flink.api.common.functions.MapFunction

class MyMap extends MapFunction[UserBean,UserBean]{
  override def map(t: UserBean): UserBean = {

    val id: String = "map_"+t.id
    UserBean(id,t.ts,t.vc+100)
  }
}
